package com.company;

public class Producer extends BaseThread{

    public Producer(String threadName, MutiBufferQueue queue) {
        super(threadName, queue);
    }

    @Override
    public void run() {
        try {
            while (true){
                int vint = (int)Math.random()%100000+1;
                this.mQueue.put(vint);
                Thread.sleep(0);
            }
        }
        catch (InterruptedException e){
        }
    }
}
